package org.linlinjava.litemall.db.util;

import cn.hutool.crypto.SecureUtil;
import org.apache.commons.lang3.RandomStringUtils;
import org.apache.commons.lang3.StringUtils;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.*;

public class ThirdPartYigong {

    private String mobile;
    private String sign;
    private String appId;
    private String appSecret;
    private String noncestr;
    private String timestamp;

    public String search(String url){
        return search(url, new HashMap<>());
    }


    public String search(String url, Map<String, String> params){
        params.put("noncestr", noncestr);
        params.put("mobile",mobile);
        params.put("appId",appId);
        params.put("timestamp", timestamp);
        params.put("sign",calculateSign(params));
        return new HttpUtil().sendGet(url, params);
    }


    public String post(String url, Map<String, String> params){
        params.put("noncestr", noncestr);
        params.put("mobile",mobile);
        params.put("appId",appId);
        params.put("timestamp", timestamp);
        params.put("sign",calculateSign(params));
        return new HttpUtil().sendPost(url, params);
    }

    public String calculateSign(Map<String, String> params){
        Map<String, String> signParams = params;
        signParams.put("secret", appSecret);
        Map<String, String> sortMap = new TreeMap<String, String>(new Comparator<String>() {
            @Override
            public int compare(String o1, String o2) {
                return o1.compareTo(o2);
            }
        });
        sortMap.putAll(signParams);
        List<String> paramsList = new ArrayList<>();
        for (Map.Entry<String, String> entry: sortMap.entrySet()){
            paramsList.add(entry.getKey() + "=" + entry.getValue());
        }
        String paramsStr = StringUtils.join(paramsList, "&");
        System.out.println(paramsStr);
        String signStr = SecureUtil.sha1(paramsStr);
        System.out.println(signStr);
        return signStr;
    }


    public ThirdPartYigong set(String mobile,String appId,String appSecret){
        ThirdPartYigong thirdPartYigong = new ThirdPartYigong();
        thirdPartYigong.setMobile(mobile);
        thirdPartYigong.setAppId(appId);
        thirdPartYigong.setAppSecret(appSecret);
        thirdPartYigong.setNoncestr(RandomStringUtils.randomAlphanumeric(16));
        thirdPartYigong.setTimestamp(String.valueOf(new Date().getTime()));
        return  thirdPartYigong;
    }

    public String getMobile() {
        return mobile;
    }

    public void setMobile(String mobile) {
        this.mobile = mobile;
    }

    public String getSign() {
        return sign;
    }

    public void setSign(String sign) {
        this.sign = sign;
    }

    public String getAppId() {
        return appId;
    }

    public void setAppId(String appId) {
        this.appId = appId;
    }

    public String getAppSecret() {
        return appSecret;
    }

    public void setAppSecret(String appSecret) {
        this.appSecret = appSecret;
    }

    public String getNoncestr() {
        return noncestr;
    }

    public void setNoncestr(String noncestr) {
        this.noncestr = noncestr;
    }

    public String getTimestamp() {
        return timestamp;
    }

    public void setTimestamp(String timestamp) {
        this.timestamp = timestamp;
    }



    public class HttpUtil{

        /**
         * 向指定URL发送GET方法的请求
         *
         * @param url
         *         发送请求的URL
         *      @param params
         *          请求参数，请求参数应该是 name1=value1&name2=value2 的形式。
         * @return URL 所代表远程资源的响应结果
         */
        public String sendGet(String url, Map<String, String> params) {
            String result = "";
            BufferedReader in = null;
            try {
                String urlNameString = url + "?" ;
                StringBuilder param = new StringBuilder();
                for (Map.Entry<String, String> entry : params.entrySet()) {
                    if (param.length() > 0) {
                        param.append("&");
                    }
                    param.append(entry.getKey());
                    param.append("=");
                    param.append(entry.getValue());

                }
                URL realUrl = new URL(urlNameString+param.toString());
                // 打开和URL之间的连接
                HttpURLConnection connection =(HttpURLConnection) realUrl.openConnection();
                // 设置通用的请求属性
                connection.setRequestProperty("accept", "*/*");
                connection.setRequestProperty("connection", "Keep-Alive");
                connection.setRequestProperty("user-agent",
                        "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
                // 建立实际的连接
                connection.connect();
                // 获取所有响应头字段
                Map<String, List<String>> map = connection.getHeaderFields();
                // 遍历所有的响应头字段
                for (String key : map.keySet()) {
                    System.out.println(key + "--->" + map.get(key));
                }
                // 定义 BufferedReader输入流来读取URL的响应
                in = new BufferedReader(new InputStreamReader(
                        connection.getInputStream()));
                String line;
                while ((line = in.readLine()) != null) {
                    result += line;
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
            // 使用finally块来关闭输入流
            finally {
                try {
                    if (in != null) {
                        in.close();
                    }
                } catch (Exception e2) {
                    e2.printStackTrace();
                }
            }
            return result;
        }


        /**
         * 向指定 URL 发送POST方法的请求
         *
         * @param url    发送请求的 URL
         * @param params 请求的参数集合
         * @return 远程资源的响应结果
         */
        @SuppressWarnings("unused")
        public String sendPost(String url, Map<String, String> params) {
            OutputStreamWriter out = null;
            BufferedReader in = null;
            StringBuilder result = new StringBuilder();
            try {
                URL realUrl = new URL(url);
                HttpURLConnection conn = (HttpURLConnection) realUrl.openConnection();
                // 发送POST请求必须设置如下两行
                conn.setDoOutput(true);
                conn.setDoInput(true);
                // POST方法
                conn.setRequestMethod("POST");
                // 设置通用的请求属性
                conn.setRequestProperty("accept", "*/*");
                conn.setRequestProperty("connection", "Keep-Alive");
                conn.setRequestProperty("user-agent",
                        "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
                conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
                conn.connect();
                // 获取URLConnection对象对应的输出流
                out = new OutputStreamWriter(conn.getOutputStream(), "UTF-8");
                // 发送请求参数
                if (params != null) {
                    StringBuilder param = new StringBuilder();
                    for (Map.Entry<String, String> entry : params.entrySet()) {
                        if (param.length() > 0) {
                            param.append("&");
                        }
                        param.append(entry.getKey());
                        param.append("=");
                        param.append(entry.getValue());

                    }

                    out.write(param.toString());
                }
                // flush输出流的缓冲
                out.flush();
                // 定义BufferedReader输入流来读取URL的响应
                in = new BufferedReader(
                        new InputStreamReader(conn.getInputStream(), "UTF-8"));
                String line;
                while ((line = in.readLine()) != null) {
                    result.append(line);
                }
            } catch (Exception e) {
            }
            //使用finally块来关闭输出流、输入流
            finally {
                try {
                    if (out != null) {
                        out.close();
                    }
                    if (in != null) {
                        in.close();
                    }
                } catch (IOException ex) {
                }
            }
            return result.toString();
        }
    }

}
